from celery import Celery


#进行Celery允许配置
# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'

#以上配置，必须创建在celery对象创建之前

#创建Celery对象
#参数main 设置脚本名
app = Celery('celery_tasks')

#加载配置文件
app.config_from_object('celery_tasks.config')

#celery自动检测任务
#第一个参数是任务列表
#元素需要添加 路径
app.autodiscover_tasks(['celery_tasks.sms'])
app.autodiscover_tasks(['celery_tasks.email'])
app.autodiscover_tasks(['celery_tasks.html'])

#worker  一条指令
#我们需要指令让Celery单独执行
#需要在虚拟环境中执行
# celery -A celery对象的路径 worker -l info
# celery -A celery_tasks.main worker -l